package com.allenkerr.queue3;

import org.springframework.stereotype.Component;

@Component
public class QueueListener<String> implements RedisQueueListener<String> {

  @Override
  public void onMessage(String value) {
    System.out.println("\n---------------------------------");
    System.out.println("QueueListener.onMessage");
    System.out.println("value = " + value);
    System.out.println("---------------------------------\n");
    try {
      Thread.sleep(500);
    } catch (InterruptedException e) {
      e.printStackTrace();
    }
  }

}  